package Value类型

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

object Opr1 {

    def main(args: Array[String]): Unit = {

        val config: SparkConf = new SparkConf().setMaster("local[*]").setAppName("")

        val sc = new SparkContext(config)

        val listRDD: RDD[Int] = sc.makeRDD(List(1, 2, 3, 4))

        val ArrayRDD: RDD[Int] = sc.parallelize(Array(1, 2, 3))

        val in: RDD[String] = sc.textFile("in")

        val mapRDD: RDD[Int] = ArrayRDD.map(x => x * 2)

        mapRDD.collect().foreach(println)

        listRDD.collect().foreach(println)

    }

}
